//package com.orkasgb.framework.orkasgbframework.flinkcdc;
//
//
//import com.ververica.cdc.connectors.mysql.source.MySqlSource;
//import com.ververica.cdc.connectors.mysql.table.StartupOptions;
//import com.ververica.cdc.debezium.JsonDebeziumDeserializationSchema;
//import org.apache.flink.api.common.eventtime.WatermarkStrategy;
//import org.apache.flink.streaming.api.datastream.DataStream;
//import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
//
//public class MySqlBinlogSourceExample {
//
//    public static void main(String[] args) throws Exception {
//        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        env.setParallelism(1);
//
//        MySqlSource<String> mySqlSource = MySqlSource.<String>builder()
//                .hostname("node-03")
//                .port(3306)
//                .databaseList("orkasgb_project_management")
//                .tableList("orkasgb_project_management.t_orkasgb_user")
//                .username("root")
//                .password("root")
//                .startupOptions(StartupOptions.initial())
//                .deserializer(new JsonDebeziumDeserializationSchema())
//                .build();
//
//        DataStream<String> stream = env.fromSource(mySqlSource, WatermarkStrategy.noWatermarks(), "MySql Binlog Source");
//
//        stream.print();
//
//        env.execute("MySql Binlog Source Example");
//    }
//}
//
//
